package com.opdar.athena.web.senders;

import org.springframework.util.concurrent.ListenableFuture;

/**
 * Created by shiju on 2017/8/16.
 */
public interface ISender<V> {
    V send(String key, byte[] value);
    V send(String topic, String key, byte[] value);
}
